//package com.java.base.exercise.current;
//
//import sun.plugin2.message.Message;
//
//import java.util.concurrent.BlockingQueue;
//import java.util.concurrent.LinkedTransferQueue;
//
///**
// * @Author RenPu
// * @Date 2021/9/13 11:09
// * @Version 1.0
// * @Description: 消息总队列
// **/
//public class MsgQueueManager {
//
//    /**
//     * 消息总队列
//     */
//    public final BlockingQueue<Message> messageQueue;
//
//    private MsgQueueManager() {
//        messageQueue = new LinkedTransferQueue<Message>();
//    }
//
//    public void put(Message msg) {
//        try {
//            messageQueue.put(msg);
//        } catch (InterruptedException e) {
//            Thread.currentThread().interrupt();
//        }
//    }
//
//    public Message take() {
//        try {
//            return messageQueue.take();
//        } catch (InterruptedException e) {
//            Thread.currentThread().interrupt();
//        }
//        return null;
//    }
//
//
//}
